package pCloud.server;

import java.util.Vector;

import pCloud.stream.AggregateBox;
import pCloud.stream.FilterBox;
import pCloud.stream.MapBox;
import pCloud.stream.QueryGraph;

public interface DataStreamHandle {

	public void init(String dir,String address, int port );
	
	public void loadStreamSchema(String streamName,QueryGraph qg);
	
	public String mergeQueryGraph();
	
	public String addQueryGraph(String ssql, String outputStream);

	public void generateQueryGraphFromObligation(Vector<FilterBox> fbs,
			Vector<MapBox> mbs, Vector<AggregateBox> abs, QueryGraph streamquery);
	
}
